package logic

import (
	"encoding/json"
	"litetalk/config"
	"litetalk/proto"

	"github.com/sirupsen/logrus"
)

func RedisPublishChannel(msg *proto.Msg) error {
	redisMsgStr, err := json.Marshal(msg)
	if err != nil {
		logrus.Errorf("logic,RedisPublishChannel Marshal err:%s", err.Error())
		return err
	}

	err = RedisClient.LPush(config.QueueName, redisMsgStr).Err()
	if err != nil {
		logrus.Errorf("logic,lpush err:%s", err.Error())
		return err
	}
	return nil
}
